package com.example.springcloud.rocketmq.service;

import com.example.springcloud.rocketmq.channel.consume.ConsumeSource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.messaging.handler.annotation.Payload;
import org.springframework.stereotype.Service;

/**
 * <pre>
 *      ReceiveService
 * </pre>
 *
 * <pre>
 * @author mazq
 * 修改记录
 *    修改后版本:     修改人：  修改日期: 2021/03/16 11:02  修改内容:
 * </pre>
 */
@Service
@Slf4j
public class ReceiveService {


    @StreamListener("input1")
    public void receiveMsg(@Payload String msg) {
        if (log.isInfoEnabled()) {
            log.info("receive message from input1:{}" , msg.toUpperCase());
        }
    }
}
